package data

import "github.com/robfig/cron/v3"

var (
	MapPtId   *MapPtIdStruct          // 用来判断 ptId 是否存在的, 解析报文过滤数据用的
	QueueMap  *QueueMapStruct         //
	RuleList  *RuleListStruct         //
	CtrlPtId  *MapPtIdStruct          // 反控的 ptId
	IdTaskMap map[string]cron.EntryID // key 是乐山id, value 是时间轮
	Jobs      *cron.Cron              // 这部分 cron任务应该提取到全局变量里面的
)

// 初始化变量
func Setup() {
	MapPtId = new(MapPtIdStruct)
	CtrlPtId = new(MapPtIdStruct)
	QueueMap = NewQueueMap()
	RuleList = NewRuleList()

	// 初始化 时间轮定时
	// 初始化 定时任务的 Map
	SetupJob()

}
